package com.youth.mq;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * @InterfaceName MyProcessor
 * @Description: TODO Stream组件提供了Processor接口，用于将消息处理后再进行发送，类似于消息中转站。
 * @Author yjwu
 * @Date 2020/3/14 16:55
 **/

@Component
public interface MyProcessor {
    String MESSAGE_INPUT = "transform_input";
    String MESSAGE_OUTPUT = "transform_output";

    @Input(MESSAGE_INPUT)
    SubscribableChannel transformInput();

    @Output(MESSAGE_OUTPUT)
    MessageChannel transformOutput();


}
